package com.cold.demo.rabbitmq.demo.work;

import org.springframework.amqp.core.Queue;
import org.springframework.boot.SpringBootConfiguration;
import org.springframework.context.annotation.Bean;

/**
 * 一个生产者对应多个消费者
 */
@SpringBootConfiguration
public class WorkConfig {
    /**
     * 简单模式的队列名称
     */
    public static final String QUEUE_NAME = "queue_work";

    /**
     * 声明一个队列，在rabbitmq中创建一个队列
     */
    @Bean(name = QUEUE_NAME)
    public Queue queue(){
        return new Queue(QUEUE_NAME,true,false,false,null);
    }
}
